974b78e2fa2270ed140eec3977d863ae2ea35464,graylog2-radio/src/main/java/org/graylog2/radio/cluster/InputService.java,InputService,unregisterInCluster,#MessageInput#,126

Before Change


    }

    public void unregisterInCluster(MessageInput input) throws ExecutionException, InterruptedException, IOException {
        final UriBuilder uriBuilder = UriBuilder.fromUri(serverUrl);
        uriBuilder.path("/system/radios/" + serverStatus.getNodeId().toString() + "/inputs/" + input.getPersistId());

        Future<Response> f = httpclient.prepareDelete(uriBuilder.build().toString())
                .setHeader("Content-Type", "application/json")
                .execute();
        Response r = f.get();
        if (r.getStatusCode() != 204) {
            throw new RuntimeException("Expected HTTP response [204] for input unregistration but got [" + r.getStatusCode() + "].");
        }
    }

After Change


    }

    public void unregisterInCluster(MessageInput input) throws ExecutionException, InterruptedException, IOException {
        final URI uri = UriBuilder.fromUri(serverUrl)
                .path("/system/radios/{radioId}/inputs/{inputId}")
                .build(nodeId.toString(), input.getPersistId());

        final Request request = new Request.Builder()
                .header(HttpHeaders.CONTENT_TYPE, APPLICATION_JSON)
                .delete()
                .url(uri.toString())
                .build();

        final Response r = httpclient.newCall(request).execute();
        if (!r.isSuccessful()) {
            throw new RuntimeException("Expected HTTP response [2xx] for input unregistration but got [" + r.code() + "].");
        }
    }